#!/bin/bash
# 定义变量：数据同步日期，表示同步哪一天日志数据
# 第1、执行shell脚本时，传递参数
# 第2、如果没有传递参数，同步前一天数据
# todo 大数据-电商数仓-07-商品主题商品诊断看板
if [ -n "$2" ] ; then
data_date=$2
else
data_date=`date -d "-1 days" +%F`
fi

# 加载数据语句
DIM_MD_AREAS_SQL="
USE product_order;
WITH t1 AS
         (
             SELECT * FROM product_order.ods_product_info
         ),t2 AS
         (
             SELECT * FROM product_order.ods_category
         )
INSERT OVERWRITE TABLE product_order.dwd_product_base_info PARTITION (dt='${data_date}')
SELECT
    p.product_id,
    p.product_name,
    p.category_id,
    c.category_name,
    p.price,
    p.status
FROM t1 p
LEFT JOIN t2 c ON p.category_id = c.category_id;

"

/opt/module/spark/bin/beeline -u jdbc:hive2://node101:10001 -n bwie -e "${DIM_MD_AREAS_SQL}"